package com.audaque.springboot.foshanupload.web.streamdemo.annoMode.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.context.annotation.Conditional;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

/**
 * @author zgb
 * @desc ...
 * @date 2024-01-07 18:34:43
 */

@Component
public interface TestChannel {
  /**
   * 生产者消息输出通道（需要与配置文件中的保持一致）
   */
  String TEST_OUTPUT = "testOutput";

  /**
   * 消息生产
   */
  @Output(TEST_OUTPUT)
  MessageChannel testOutput();

  /**
   * 消费者消息输入通道（需要与配置文件中的保持一致）
   */
  String TEST_INPUT = "testInput";

  /**
   * 消息消费
   */
  @Input(TEST_INPUT)
  SubscribableChannel testInput();
}

